草庐IT

CountDownLatch和ExecutorService 线程池cachedThreadPool.submit

全部标签

c++ - Pthread 程序运行速度随着线程的增加而变慢

我是并行编程的初学者,我尝试使用pthread库编写并行程序。我在8处理器计算机上运行该程序。问题是,当我增加NumProcs时,每个线程都会变慢,尽管它们的任务总是相同的。有人可以帮我弄清楚发生了什么吗?`#defineMAX_NUMP16usingnamespacestd;intNumProcs;pthread_mutex_tSyncLock;/*mutex*/pthread_cond_tSyncCV;/*conditionvariable*/intSyncCount;/*numberofprocessorsatthebarriersofar*/pthread_mutex_tThr

穿越Redis单线程迷雾:从面试场景到技术内核的解读

目录​编辑前言Redis中的多线程I/O多线程Redis中的多进程结论延伸阅读前言很多人都遇到过这么一道面试题:Redis是单线程还是多线程?这个问题既简单又复杂。说他简单是因为大多数人都知道Redis是单线程,说复杂是因为这个答案其实并不准确。难道Redis不是单线程?我们启动一个Redis实例,验证一下就知道了。Redis安装部署方式如下所示:// 下载wget https://download.redis.io/redis-stable.tar.gztar -xzvf redis-stable.tar.gz// 编译安装cd redis-stablemake// 验证是否安装成功./sr

C++ 简单的新建和删除线程和内存泄漏

我在我的代码中使用了线程并发现了一些内存泄漏,所以我测试了以下简单的代码。#includevoidfoo(){}intmain(){for(;;){std::thread*th=newstd::thread(foo)th->join();deleteth;}}我在未更改任何设置的情况下使用VC++Release模式对其进行了测试,我也发现了内存泄漏。当我使用Windows任务管理器检查进程时,这个程序的内存在增加。我认为我代码中的delete不起作用。有什么原因会导致内存泄漏吗?更多细节查看评论和答案后,我又运行了几分钟程序。几分钟后我发现测试程序没有使用更多内存。但是我不确定为什么t

c++ - 如何使用 boost::statecart 在固定数量的线程上多路复用多个异步状态机?

假设我有许多用boost::statecart定义的异步状态机。运行多个异步状态机的明确记录机制是将其中一个或多个固定到一个线程。但是,出于我的目的,我需要运行很多很多异步状态机,而每个线程一个是行不通的。此外,任何给定状态机完成的工作量是不可预测的,因此将状态机分配给固定线程会导致不平衡。相反,我想要一个线程池,空闲线程可以在其中从队列中提取一些工作量。这里需要注意一些事情,以便按顺序将事件传送到给定的状态机。大概开始的地方是涉及实现Scheduler和FifoWorker概念来做我想做的事情,分别作为fifo_scheduler和fifo_worker类的替代方案。但是,我想知道这

c++ - 使用 QueuedConnection 还是 QMutex 来使对象线程安全?

我正在构建一个需要加载数千个HTML文件的应用程序,分析它们然后将它们放入全局的HashMap之类的东西中,我决定使用多线程来加快速度。所以问题出现了,我应该使用QueuedConnection用于信号/槽或QMutex使HashMap线程安全。我使用QueueConnection使一切变得更简单,我创建了很多子线程来加载并将指针发回主线程以分析它们并将它们放入HashMap,然后它工作正常。然而,当我读到一些评论说QueueConnection实际上非常耗时时,我开始重新构建我的代码并使用QMutex使我的HashMap线程安全,然后我可以完成所有工作(加载,分析,将它们放到子线程中

多线程系列(七) -ThreadLocal 用法及内存泄露分析

一、简介在Javaweb项目中,想必很多的同学对ThreadLocal这个类并不陌生,它最常用的应用场景就是用来做对象的跨层传递,避免多次传递,打破层次之间的约束。比如下面这个HttpServletRequest参数传递的简单例子!publicclassRequestLocal{/***线程本地变量*/privatestaticThreadLocallocal=newThreadLocal();/***存储请求对象*@paramrequest*/publicstaticvoidset(HttpServletRequestrequest){local.set(request);}/***获取请求

多线程系列(八) -ReentrantLock基本用法介绍

一、简介在之前的线程系列文章中,我们介绍到了使用synchronized关键字可以实现线程同步安全的效果,以及采用wait()、notify()和notifyAll()方法,可以实现多个线程之间的通信协调,基本可以满足并发编程的需求。但是采用synchronized进行加锁,这种锁一般都比较重,里面的实现机制也非常复杂,同时获取锁时必须一直等待,没有额外的尝试机制,如果编程不当,可能就容易发生死锁现象。从JDK1.5开始,引入了一个高级的处理并发的java.util.concurrent包,它提供了大量更高级的并发功能,能大大的简化多线程程序的编写。比如我们今天要介绍的java.util.co

c++ - Qt 无法将目标移动到线程

我的Qt5.7(在Windows10上)应用程序中遇到了一个奇怪的错误,并且找不到导致这种行为的常见罪魁祸首:被移动的对象有一个父对象——当然不是这样尝试将对象拉到线程而不是将其推送-这是错误的原因,但我不知道它来自哪里完整的错误信息是QObject::moveToThread:Currentthread(0x2afcca68)isnottheobject'sthread(0x34f4acc8).Cannotmovetotargetthread(0x34f4adc8)QObject::setParent:Cannotsetparent,newparentisinadifferentth

c++ - 关闭时 Boost 日志中的 Boost 线程访问冲突

我有一个使用boost日志记录的应用程序。在关闭期间,它会在空指针访问时发生访问冲突。当我单步执行代码到失败点时,似乎正在取消分配boost::logdll,然后boost::thread代码尝试访问曾经被日志dll占用的内存。我没有在自己的代码中使用任何boost线程,因此假设boost-threaddll被boostlog使用。为了确保在关闭之前销毁所有接收器,我调用了:core->flush()和core->remove_all_sinks()我使用的是boost1.60,也曾在boost1.63上尝试过。相同的结果。有没有办法确保在退出/卸载dll之前完全关闭boost日志记录

c++ - FFmpeg:使用自定义线程池进行并行编码

我试图实现的其中一件事是通过FFmpeg的cAPI进行并行编码。这看起来开箱即用。但是,我稍微更改了目标帖子:在现有的应用程序中,我手边已经有一个线程池。我不想通过FFmpeg使用另一个线程池,而是想在我的应用程序中重用现有的线程池。研究了最新的FFmpegtrunk文档后,它看起来很有可能。使用一些FFmpeg示例代码,我创建了一个示例应用程序来演示我正在尝试实现的目标(见下文)。示例应用使用mp2v编解码器生成纯视频mpeg2ts。我遇到的问题是自定义“thread_execute”或“thread_execute2”从未被调用。尽管事实上编解码器似乎表明支持线程。请注意,我还没有